//package com.changgou.canal.config;
//
//import org.springframework.amqp.core.*;
//import org.springframework.beans.factory.annotation.Qualifier;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
///**
// * @Author: HuangFu
// * @Date: 2020/2/1 10:26
// * @Description: 商品消息队列配置类
// */
//@Configuration
//public class GoodsRabbitMQConfig {
//    /**
//     * 商品上架交换机
//     */
//    public final static String GOODS_UP_EXCHANGE = "goods_up_exchange";
//    /**
//     * 商品下架删除交换机
//     */
//    public final static String GOODS_DEL_EXCHANGE = "goods_de22l_exchange";
//    /**
//     * 查询新增队列
//     */
//    public final static String SEARCH_ADD_QUEUE = "search_add_queue";
//    /**
//     * 查询删除队列
//     */
//    public final static String SEARCH_DEL_QUEUE = "search_d22el_queue";
//
//
//    /**
//     * 声明队列
//     * @return
//     */
//    @Bean(SEARCH_ADD_QUEUE)
//    public Queue SEARCH_ADD_QUEUE(){
//        return  QueueBuilder.durable(SEARCH_ADD_QUEUE).build();
//    }
//
//    @Bean(SEARCH_DEL_QUEUE)
//    public Queue SEARCH_DL_QUEUE(){
//        return  QueueBuilder.durable(SEARCH_DEL_QUEUE).build();
//    }
//
//
//    /**
//     * 定义fanout广播模式交换机
//     * @return
//     */
//    @Bean(GOODS_UP_EXCHANGE)
//    public Exchange GOODS_UP_EXCHANGE(){
//        //durable 设置是否持久化
//        return ExchangeBuilder.fanoutExchange(GOODS_UP_EXCHANGE).durable(true).build();
//    }
//
//    /**
//     * 商品下架交换机
//     * @return
//     */
//    @Bean(GOODS_DEL_EXCHANGE)
//    public Exchange GOODS_DL_EXCHANGE(){
//        //durable 设置是否持久化
//        return ExchangeBuilder.fanoutExchange(GOODS_DEL_EXCHANGE).durable(true).build();
//    }
//
//
//    /**
//     * 商品上架绑定队列到交换机上
//     * @param queue
//     * @param exchange
//     * @return
//     */
//    @Bean("goods_up_queue_exchange")
//    public Binding goodsUpQueueExchange(@Qualifier(SEARCH_ADD_QUEUE) Queue queue
//            , @Qualifier(GOODS_UP_EXCHANGE) Exchange exchange){
//        return BindingBuilder.bind(queue).to(exchange).with("").noargs();
//    }
//
//    /**
//     * 商品下架绑定队列到交换机上
//     * @param queue
//     * @param exchange
//     * @return
//     */
//    @Bean("goods_del_queue_exchange")
//    public Binding goodsDelQueueExchange(@Qualifier(SEARCH_DEL_QUEUE) Queue queue
//            ,@Qualifier(GOODS_DEL_EXCHANGE) Exchange exchange){
//        return BindingBuilder.bind(queue).to(exchange).with("").noargs();
//    }
//}
